var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
function _connect(callback){
	MongoClient.connect(url, function(err, db) {
	  if (err) throw err;
	  callback(err,db);
	  db.close();
	});
}

exports.insert=function(dbase,collectionName,myobj,callback){
	_connect(function(a,b){
		// db代表查找数据库
		b.db(dbase).collection(collectionName).insertMany(myobj, function(err, result) {
        if (err) throw err;
        console.log("文档插入成功");
        callback(err, result)
        db.close();
    });
	})
}
exports.find=function(dbase,collectionName,myobj,callback){
	_connect(function(a,b){
		// db代表查找数据库
		b.db(dbase).collection(collectionName).find().toArray((err,result)=>{
			if(err) return ;
			callback(err, result)
		})
	})
}